Node / ReticulumProjects / Reticulum.git / files / RNS / Utilities / rnsh / protocol.py

Displaying Raw • Download

T8b949e# Based on the original rnsh program by Aaron Heise (@acehoss)

T8b949e# https://github.com/acehoss/rnsh - MIT License - Copyright (c) 2023 Aaron Heise

T8b949e# This version of rnsh is included in RNS under the Reticulum License

T8b949e#

T8b949e# Reticulum License

T8b949e#

T8b949e# Copyright (c) 2016-2026 Mark Qvist

T8b949e#

T8b949e# Permission is hereby granted, free of charge, to any person obtaining a copy

T8b949e# of this software and associated documentation files (the "Software"), to deal

T8b949e# in the Software without restriction, including without limitation the rights

T8b949e# to use, copy, modify, merge, publish, distribute, sublicense, and/or sell

T8b949e# copies of the Software, and to permit persons to whom the Software is

T8b949e# furnished to do so, subject to the following conditions:

T8b949e#

T8b949e# - The Software shall not be used in any kind of system which includes amongst

T8b949e# its functions the ability to purposefully do harm to human beings.

T8b949e#

T8b949e# - The Software shall not be used, directly or indirectly, in the creation of

T8b949e# an artificial intelligence, machine learning or language model training

T8b949e# dataset, including but not limited to any use that contributes to the

T8b949e# training or development of such a model or algorithm.

T8b949e#

T8b949e# - The above copyright notice and this permission notice shall be included in

T8b949e# all copies or substantial portions of the Software.

T8b949e#

T8b949e# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR

T8b949e# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,

T8b949e# FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE

T8b949e# AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER

T8b949e# LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,

T8b949e# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE

T8b949e# SOFTWARE.

Tff7b72from T7ee787__future__ Tff7b72import Te6edf3annotations

Tff7b72import T7ee787RNS

Tff7b72from T7ee787RNST7ee787.T7ee787vendor Tff7b72import Te6edf3umsgpack

Tff7b72from T7ee787RNST7ee787.T7ee787Buffer Tff7b72import Te6edf3StreamDataMessage Tff7b72as Te6edf3RNSStreamDataMessage

Tff7b72import T7ee787RNST7ee787.T7ee787UtilitiesT7ee787.T7ee787rnshT7ee787.T7ee787retry

Tff7b72import T7ee787abc

Tff7b72import T7ee787contextlib

Tff7b72import T7ee787struct

Tff7b72from T7ee787abc Tff7b72import Te6edf3ABCTb4b4b4, Te6edf3abstractmethod

Te6edf3MSG_MAGIC Tff7b72= T79c0ff0xac

Te6edf3PROTOCOL_VERSION Tff7b72= T79c0ff1

Tff7b72def Td2a8ff_make_MSGTYPETb4b4b4(Te6edf3valTb4b4b4: Tffa657intTb4b4b4)Tb4b4b4:

Tff7b72return Tb4b4b4(Tb4b4b4(Te6edf3MSG_MAGIC Tff7b72<< T79c0ff8Tb4b4b4) Tff7b72& T79c0ff0xff00Tb4b4b4) Tff7b72| Tb4b4b4(Te6edf3val Tff7b72& T79c0ff0x00ffTb4b4b4)

Tff7b72class T56d364NoopMessageTb4b4b4(Te6edf3RNSTff7b72.Td2a8ffMessageBaseTb4b4b4)Tb4b4b4:

Te6edf3MSGTYPE Tff7b72= Te6edf3_make_MSGTYPETb4b4b4(T79c0ff0Tb4b4b4)

Tff7b72def Td2a8ffpackTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tffa657bytesTb4b4b4: Tff7b72return Tffa657bytesTb4b4b4(Tb4b4b4)

Tff7b72def Td2a8ffunpackTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3rawTb4b4b4)Tb4b4b4: Tff7b72pass

Tff7b72class T56d364WindowSizeMessageTb4b4b4(Te6edf3RNSTff7b72.Td2a8ffMessageBaseTb4b4b4)Tb4b4b4:

Te6edf3MSGTYPE Tff7b72= Te6edf3_make_MSGTYPETb4b4b4(T79c0ff2Tb4b4b4)

Tff7b72def Tff7b72__init__Tb4b4b4(Tff7b72selfTb4b4b4, Te6edf3rowsTb4b4b4: Tffa657int Tff7b72= Tff7b72NoneTb4b4b4, Te6edf3colsTb4b4b4: Tffa657int Tff7b72= Tff7b72NoneTb4b4b4, Te6edf3hpixTb4b4b4: Tffa657int Tff7b72= Tff7b72NoneTb4b4b4, Te6edf3vpixTb4b4b4: Tffa657int Tff7b72= Tff7b72NoneTb4b4b4)Tb4b4b4:

Tffa657superTb4b4b4(Tb4b4b4)Tff7b72.Td2a8ff__init__Tb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffrows Tff7b72= Te6edf3rows

Tff7b72selfTff7b72.Td2a8ffcols Tff7b72= Te6edf3cols

Tff7b72selfTff7b72.Td2a8ffhpix Tff7b72= Te6edf3hpix

Tff7b72selfTff7b72.Td2a8ffvpix Tff7b72= Te6edf3vpix

Tff7b72def Td2a8ffpackTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tffa657bytesTb4b4b4: Tff7b72return Te6edf3umsgpackTff7b72.Td2a8ffpackbTb4b4b4(Tb4b4b4(Tff7b72selfTff7b72.Td2a8ffrowsTb4b4b4, Tff7b72selfTff7b72.Td2a8ffcolsTb4b4b4, Tff7b72selfTff7b72.Td2a8ffhpixTb4b4b4, Tff7b72selfTff7b72.Td2a8ffvpixTb4b4b4)Tb4b4b4)

Tff7b72def Td2a8ffunpackTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3rawTb4b4b4)Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffrowsTb4b4b4, Tff7b72selfTff7b72.Td2a8ffcolsTb4b4b4, Tff7b72selfTff7b72.Td2a8ffhpixTb4b4b4, Tff7b72selfTff7b72.Td2a8ffvpix Tff7b72= Te6edf3umsgpackTff7b72.Td2a8ffunpackbTb4b4b4(Te6edf3rawTb4b4b4)

Tff7b72class T56d364ExecuteCommandMesssageTb4b4b4(Te6edf3RNSTff7b72.Td2a8ffMessageBaseTb4b4b4)Tb4b4b4:

Te6edf3MSGTYPE Tff7b72= Te6edf3_make_MSGTYPETb4b4b4(T79c0ff3Tb4b4b4)

Tff7b72def Tff7b72__init__Tb4b4b4(Tff7b72selfTb4b4b4, Te6edf3cmdlineTb4b4b4: Tb4b4b4[Tffa657strTb4b4b4] Tff7b72= Tff7b72NoneTb4b4b4, Te6edf3pipe_stdinTb4b4b4: Tffa657bool Tff7b72= Tff7b72FalseTb4b4b4, Te6edf3pipe_stdoutTb4b4b4: Tffa657bool Tff7b72= Tff7b72FalseTb4b4b4,

Te6edf3pipe_stderrTb4b4b4: Tffa657bool Tff7b72= Tff7b72FalseTb4b4b4, Te6edf3tcflagsTb4b4b4: Tb4b4b4[Tffa657anyTb4b4b4] Tff7b72= Tff7b72NoneTb4b4b4, Te6edf3termTb4b4b4: Tffa657str Tff7b72| Tff7b72None Tff7b72= Tff7b72NoneTb4b4b4, Te6edf3rowsTb4b4b4: Tffa657int Tff7b72= Tff7b72NoneTb4b4b4,

Te6edf3colsTb4b4b4: Tffa657int Tff7b72= Tff7b72NoneTb4b4b4, Te6edf3hpixTb4b4b4: Tffa657int Tff7b72= Tff7b72NoneTb4b4b4, Te6edf3vpixTb4b4b4: Tffa657int Tff7b72= Tff7b72NoneTb4b4b4)Tb4b4b4:

Tffa657superTb4b4b4(Tb4b4b4)Tff7b72.Td2a8ff__init__Tb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffcmdline Tff7b72= Te6edf3cmdline

Tff7b72selfTff7b72.Td2a8ffpipe_stdin Tff7b72= Te6edf3pipe_stdin

Tff7b72selfTff7b72.Td2a8ffpipe_stdout Tff7b72= Te6edf3pipe_stdout

Tff7b72selfTff7b72.Td2a8ffpipe_stderr Tff7b72= Te6edf3pipe_stderr

Tff7b72selfTff7b72.Td2a8fftcflags Tff7b72= Te6edf3tcflags

Tff7b72selfTff7b72.Td2a8ffterm Tff7b72= Te6edf3term

Tff7b72selfTff7b72.Td2a8ffrows Tff7b72= Te6edf3rows

Tff7b72selfTff7b72.Td2a8ffcols Tff7b72= Te6edf3cols

Tff7b72selfTff7b72.Td2a8ffhpix Tff7b72= Te6edf3hpix

Tff7b72selfTff7b72.Td2a8ffvpix Tff7b72= Te6edf3vpix

Tff7b72def Td2a8ffpackTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tffa657bytesTb4b4b4:

Tff7b72return Te6edf3umsgpackTff7b72.Td2a8ffpackbTb4b4b4(Tb4b4b4(Tff7b72selfTff7b72.Td2a8ffcmdlineTb4b4b4, Tff7b72selfTff7b72.Td2a8ffpipe_stdinTb4b4b4, Tff7b72selfTff7b72.Td2a8ffpipe_stdoutTb4b4b4, Tff7b72selfTff7b72.Td2a8ffpipe_stderrTb4b4b4,

Tff7b72selfTff7b72.Td2a8fftcflagsTb4b4b4, Tff7b72selfTff7b72.Td2a8fftermTb4b4b4, Tff7b72selfTff7b72.Td2a8ffrowsTb4b4b4, Tff7b72selfTff7b72.Td2a8ffcolsTb4b4b4, Tff7b72selfTff7b72.Td2a8ffhpixTb4b4b4, Tff7b72selfTff7b72.Td2a8ffvpixTb4b4b4)Tb4b4b4)

Tff7b72def Td2a8ffunpackTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3rawTb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffcmdlineTb4b4b4, Tff7b72selfTff7b72.Td2a8ffpipe_stdinTb4b4b4, Tff7b72selfTff7b72.Td2a8ffpipe_stdoutTb4b4b4, Tff7b72selfTff7b72.Td2a8ffpipe_stderrTb4b4b4, Tff7b72selfTff7b72.Td2a8fftcflagsTb4b4b4, Tff7b72selfTff7b72.Td2a8fftermTb4b4b4, Tff7b72selfTff7b72.Td2a8ffrowsTb4b4b4, \

Tff7b72selfTff7b72.Td2a8ffcolsTb4b4b4, Tff7b72selfTff7b72.Td2a8ffhpixTb4b4b4, Tff7b72selfTff7b72.Td2a8ffvpix Tff7b72= Te6edf3umsgpackTff7b72.Td2a8ffunpackbTb4b4b4(Te6edf3rawTb4b4b4)

T8b949e# Create a version of RNS.Buffer.StreamDataMessage that we control

Tff7b72class T56d364StreamDataMessageTb4b4b4(Te6edf3RNSStreamDataMessageTb4b4b4)Tb4b4b4:

Te6edf3MSGTYPE Tff7b72= Te6edf3_make_MSGTYPETb4b4b4(T79c0ff4Tb4b4b4)

Te6edf3STREAM_ID_STDIN Tff7b72= T79c0ff0

Te6edf3STREAM_ID_STDOUT Tff7b72= T79c0ff1

Te6edf3STREAM_ID_STDERR Tff7b72= T79c0ff2

Tff7b72class T56d364VersionInfoMessageTb4b4b4(Te6edf3RNSTff7b72.Td2a8ffMessageBaseTb4b4b4)Tb4b4b4:

Te6edf3MSGTYPE Tff7b72= Te6edf3_make_MSGTYPETb4b4b4(T79c0ff5Tb4b4b4)

Tff7b72def Tff7b72__init__Tb4b4b4(Tff7b72selfTb4b4b4, Te6edf3sw_versionTb4b4b4: Tffa657str Tff7b72= Tff7b72NoneTb4b4b4)Tb4b4b4:

Tffa657superTb4b4b4(Tb4b4b4)Tff7b72.Td2a8ff__init__Tb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffsw_version Tff7b72= Te6edf3sw_version Tff7b72or Te6edf3RNSTff7b72.Td2a8ffUtilitiesTff7b72.Td2a8ffrnshTff7b72.Td2a8ff__version__

Tff7b72selfTff7b72.Td2a8ffprotocol_version Tff7b72= Te6edf3PROTOCOL_VERSION

Tff7b72def Td2a8ffpackTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tffa657bytesTb4b4b4: Tff7b72return Te6edf3umsgpackTff7b72.Td2a8ffpackbTb4b4b4(Tb4b4b4(Tff7b72selfTff7b72.Td2a8ffsw_versionTb4b4b4, Tff7b72selfTff7b72.Td2a8ffprotocol_versionTb4b4b4)Tb4b4b4)

Tff7b72def Td2a8ffunpackTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3rawTb4b4b4)Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffsw_versionTb4b4b4, Tff7b72selfTff7b72.Td2a8ffprotocol_version Tff7b72= Te6edf3umsgpackTff7b72.Td2a8ffunpackbTb4b4b4(Te6edf3rawTb4b4b4)

Tff7b72class T56d364ErrorMessageTb4b4b4(Te6edf3RNSTff7b72.Td2a8ffMessageBaseTb4b4b4)Tb4b4b4:

Te6edf3MSGTYPE Tff7b72= Te6edf3_make_MSGTYPETb4b4b4(T79c0ff6Tb4b4b4)

Tff7b72def Tff7b72__init__Tb4b4b4(Tff7b72selfTb4b4b4, Te6edf3msgTb4b4b4: Tffa657str Tff7b72= Tff7b72NoneTb4b4b4, Te6edf3fatalTb4b4b4: Tffa657bool Tff7b72= Tff7b72FalseTb4b4b4, Te6edf3dataTb4b4b4: Tffa657dict Tff7b72= Tff7b72NoneTb4b4b4)Tb4b4b4:

Tffa657superTb4b4b4(Tb4b4b4)Tff7b72.Td2a8ff__init__Tb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffmsg Tff7b72= Te6edf3msg

Tff7b72selfTff7b72.Td2a8fffatal Tff7b72= Te6edf3fatal

Tff7b72selfTff7b72.Td2a8ffdata Tff7b72= Te6edf3data

Tff7b72def Td2a8ffpackTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tffa657bytesTb4b4b4: Tff7b72return Te6edf3umsgpackTff7b72.Td2a8ffpackbTb4b4b4(Tb4b4b4(Tff7b72selfTff7b72.Td2a8ffmsgTb4b4b4, Tff7b72selfTff7b72.Td2a8fffatalTb4b4b4, Tff7b72selfTff7b72.Td2a8ffdataTb4b4b4)Tb4b4b4)

Tff7b72def Td2a8ffunpackTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3rawTb4b4b4: Tffa657bytesTb4b4b4)Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffmsgTb4b4b4, Tff7b72selfTff7b72.Td2a8fffatalTb4b4b4, Tff7b72selfTff7b72.Td2a8ffdata Tff7b72= Te6edf3umsgpackTff7b72.Td2a8ffunpackbTb4b4b4(Te6edf3rawTb4b4b4)

Tff7b72class T56d364CommandExitedMessageTb4b4b4(Te6edf3RNSTff7b72.Td2a8ffMessageBaseTb4b4b4)Tb4b4b4:

Te6edf3MSGTYPE Tff7b72= Te6edf3_make_MSGTYPETb4b4b4(T79c0ff7Tb4b4b4)

Tff7b72def Tff7b72__init__Tb4b4b4(Tff7b72selfTb4b4b4, Te6edf3return_codeTb4b4b4: Tffa657int Tff7b72= Tff7b72NoneTb4b4b4)Tb4b4b4:

Tffa657superTb4b4b4(Tb4b4b4)Tff7b72.Td2a8ff__init__Tb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffreturn_code Tff7b72= Te6edf3return_code

Tff7b72def Td2a8ffpackTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tffa657bytesTb4b4b4: Tff7b72return Te6edf3umsgpackTff7b72.Td2a8ffpackbTb4b4b4(Tff7b72selfTff7b72.Td2a8ffreturn_codeTb4b4b4)

Tff7b72def Td2a8ffunpackTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3rawTb4b4b4: Tffa657bytesTb4b4b4)Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffreturn_code Tff7b72= Te6edf3umsgpackTff7b72.Td2a8ffunpackbTb4b4b4(Te6edf3rawTb4b4b4)

Te6edf3message_types Tff7b72= Tb4b4b4[Te6edf3NoopMessageTb4b4b4, Te6edf3VersionInfoMessageTb4b4b4, Te6edf3WindowSizeMessageTb4b4b4, Te6edf3ExecuteCommandMesssageTb4b4b4, Te6edf3StreamDataMessageTb4b4b4,

Te6edf3CommandExitedMessageTb4b4b4, Te6edf3ErrorMessageTb4b4b4]

Tff7b72def Td2a8ffregister_message_typesTb4b4b4(Te6edf3channelTb4b4b4: Te6edf3RNSTff7b72.Td2a8ffChannelTff7b72.Td2a8ffChannelTb4b4b4)Tb4b4b4:

Tff7b72for Te6edf3message_type Tff7b72in Te6edf3message_typesTb4b4b4: Te6edf3channelTff7b72.Td2a8ffregister_message_typeTb4b4b4(Te6edf3message_typeTb4b4b4)